package com.li.flink.datastream

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

object StreamExecutionEnvironmentOp {
  def main(args: Array[String]): Unit = {
    //通常，您只需要使用getExecutionEnvironment()，因为这将根据上下文执行正确的操作：
    // 如果您在 IDE 中执行程序或作为常规 Java 程序，它将创建一个本地环境，该环境将在本地计算机上执行您的程序.
    // 如果您从程序中创建了一个 JAR 文件，并通过命令行调用它，Flink 集群管理器将执行您的 main 方法，
    // getExecutionEnvironment()并返回一个执行环境，用于在集群上执行您的程序。
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    //获取远程执行环境
    val envRemote = StreamExecutionEnvironment.createRemoteEnvironment("bigdata04", 9001)
  }
}
